# -*- coding: utf-8 -*-
from datetime import timedelta
from utils.operators.external_dag_sensor import ExternalDagSensor
from airflow.operators.dummy_operator import DummyOperator

jms_dim__dim_network_whole_massage = ExternalDagSensor(
    task_id='jms_dim__dim_network_whole_massage',
    external_dag_id='jms_core_wide_day',
    external_task_id='jms_dim__dim_network_whole_massage',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)
jms_dim__dim_lmdm_sys_network_distributi = ExternalDagSensor(
    task_id='jms_dim__dim_lmdm_sys_network_distributi',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_lmdm_sys_network_distributi',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)
jms_dim__dim_tab_terminal_secret_base = ExternalDagSensor(
    task_id='jms_dim__dim_tab_terminal_secret_base',
    external_dag_id='jms_dim_tab_day',
    external_task_id='jms_dim__dim_tab_terminal_secret_base',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)
jms_dim__dim_tab_agent_point_base = ExternalDagSensor(
    task_id='jms_dim__dim_tab_agent_point_base',
    external_dag_id='jms_dim_tab_day',
    external_task_id='jms_dim__dim_tab_agent_point_base',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)

jms_dim__dim_lmdm_sys_second_code = ExternalDagSensor(
    task_id='jms_dim__dim_lmdm_sys_second_code',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_lmdm_sys_second_code',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)

jms_dim__dim_lmdm_sys_first_code = ExternalDagSensor(
    task_id='jms_dim__dim_lmdm_sys_first_code',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_lmdm_sys_first_code',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)

jms_dim__dim_sys_network_detail_dt = ExternalDagSensor(
    task_id='jms_dim__dim_sys_network_detail_dt',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_sys_network_detail_dt',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)

jms_dim__dim_lmdm_sys_network_expand = ExternalDagSensor(
    task_id='jms_dim__dim_lmdm_sys_network_expand',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_lmdm_sys_network_expand',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)

jms_dim__dim_lmdm_sys_customer_addition = ExternalDagSensor(
    task_id='jms_dim__dim_lmdm_sys_customer_addition',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_lmdm_sys_customer_addition',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)

jms_dim__dim_lmdm_sys_customer = ExternalDagSensor(
    task_id='jms_dim__dim_lmdm_sys_customer',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_lmdm_sys_customer',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)


jms_dim__dim_yl_oms_order_interceptor_base = ExternalDagSensor(
    task_id='jms_dim__dim_yl_oms_order_interceptor_base',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_yl_oms_order_interceptor_base',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)
jms_dim__dim_lmdm_sys_network = ExternalDagSensor(
    task_id='jms_dim__dim_lmdm_sys_network',
    external_dag_id='jms_dim_lmdm_day',
    external_task_id='jms_dim__dim_lmdm_sys_network',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)
